package com.hzlj.position.dbsync.common.service;

import com.hzlj.position.dbsync.common.common.dto.syncOffsetConfig.SyncOffsetConfigUpsertDTO;

import java.util.Collection;
import java.util.Date;

/**
 * 同步offset配置表(SyncOffsetConfig)表服务接口
 *
 * @author lifh
 * @date 2023-11-30 16:00:38
 */
public interface SyncOffsetConfigService {

    void upsert(String jgCode, String syncType, Date syncTime);

    void upsert(String jgCode, String syncType, String syncOffset);

    Date getLatestTime(String jgCode, String syncType);

    String getLatestOffset(String jgCode, String syncType);

    void upsert(Collection<SyncOffsetConfigUpsertDTO> dtos);
}
